package io.kimmking.mq.alphamq;

public interface ISubscriber {
    
    void addMessageListener(String topic, IMessageListener listener);
    
}
